package cn.hallele.leinsteining.mc.infrastructure.message.kafka.serialization;

import cn.hallele.leinsteining.mc.infrastructure.message.utils.CodecUtil;
import org.apache.kafka.common.serialization.Deserializer;

/**
 * GGSDeSerializer
 *
 * @author anle5
 * @since 2023/12/9 星期六 0:35
 */
public class LByteDeSerializer implements Deserializer<Object> {
    @Override
    public Object deserialize(String topic, byte[] data) {
        return CodecUtil.byte2Obj(data);
    }
}
